package com.shiyun.kafka_prod;

import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Date;

/**
 * 类 描 述: kafka消费
 * 作   者: 史 云
 * 版   本: 1.0.0
 * 时   间: 2022年01月11日  10:00:00
 */
@Component
@Slf4j
public class KafkaConsumer {
    @Resource
    KafkaTemplate<String,String> kafkaTemplate;

    /**
     * 方法描述: 测试发送消息
     * 作    者: 史 云
     * 时    间: 2022年05月25日  14:13:33
     */
    @KafkaListener(topics = {"test"},groupId = "shiyun_test")
    public void listen(ConsumerRecord<String, String> record){
        Object value = record.value();
        System.out.println(JSONUtil.toJsonStr(value));
        kafkaTemplate.send("test", "我在"+DateUtil.formatDateTime(new Date())+"尝试发送消息》》》》》》》》》》》》》》》》》");
    }
}
